#!/bin/bash
# 增量抽取脚本

# 获取ETL时间  今天
dt=`date -d '-1 day' +"%Y-%m-%d"`
# 定义需要全量抽取的 表名  数据集
arr=(AML_ALERT AML_CUSTOMER_MASTER AML_MONITORING_RULE AML_SCREENING_RESULT AML_SUSPICIOUS_TXN_REPORT AML_TRANSACTION_DETAIL AML_UBO_INFO AML_WATCHLIST_DETAIL)

# 循环数值
for i in ${arr[@]}; do
hive_tb="ODS_$i"
  sqoop import \
  --connect jdbc:oracle:thin:@192.168.65.48:1521/orcl \
  --username AML \
  --password 123456 \
  --table $i \
  --where "to_char(CREATE_DATE,'yyyy-mm-dd') = $dt "
  --hcatalog-database ods \
  --hcatalog-table $hive_tb \
  --hive-partition-key etl_date \
  --hive-partition-value $dt \
  -m 1
done
